package com.gjy.rocketmq;

import org.apache.rocketmq.common.message.Message;

/**
 * @author gjy
 * @version 1.0
 * @since 2024-05-01 22:30:34
 */
public class MqUtil {

    public static final String NAME_SRV = "192.168.253.129:9876";

    public static final String PRODUCER = "PRODUCER_TEST";
    public static final String CONSUMER = "CONSUMER_TEST";
    public static final String TOPIC = "TOPIC_TEST";
    public static final String TAG = "TAG_TEST";
    public static final String KEY = "KEY_TEST";

    public static Message buildMessage() {
        return new Message(TOPIC, TAG, KEY, "Hello RocketMQ".getBytes());
    }
}
